2b1e214e5e2fb1190bf72f5970bd7a77c3358d48,conduit-worker/src/main/java/com/inmobi/conduit/Conduit.java,Conduit,copyAuditUtilJarToClusterFs,#Cluster#String#,240

Before Change


    // copy AuditUtil source jar into /conduit/system/tmp/jars path
    Path AuditUtilJarDestPath = new Path(jarsPath, "messaging-client-core.jar");
    if (!clusterFS.exists(AuditUtilJarDestPath)) {
      clusterFS.copyFromLocalFile(new Path(auditUtilSrcJar), AuditUtilJarDestPath);
    }
  }

After Change


    if (clusterFS.exists(AuditUtilJarDestPath)) {
      clusterFS.delete(AuditUtilJarDestPath, true);
    }
    clusterFS.copyFromLocalFile(new Path(auditUtilSrcJar), AuditUtilJarDestPath);
  }

  protected LocalStreamService getLocalStreamService(ConduitConfig config,